package com.yj.rocketmq.handler;

import org.apache.rocketmq.common.message.MessageExt;

import java.io.UnsupportedEncodingException;

public interface IMqConsumerHandler {

    /**
     * 默认消息处理函数
     *
     * @param message
     * @param topic
     * @param tag
     */
    void handleMessage(MessageExt message, String topic, String tag) throws UnsupportedEncodingException;
}
